package org.apache.flink.runtime.client;

import org.apache.flink.api.common.ConsumerID;

/**
 * An exception which is thrown by the JobClient if a job is aborted as a result of a user
 * cancellation.
 */
public class ConsumeCancellationException extends ConsumeException {

    private static final long serialVersionUID = 2818087325120827526L;

    public ConsumeCancellationException(ConsumerID jobID, String msg, Throwable cause) {
        super(jobID, msg, cause);
    }
}
